package com.zc.common.mq.product;

import java.io.Serializable;

/**
 * <p>Description : </p>
 *
 * @author : xuhongcao
 * @version : v1.0.0
 * @since : 2/4/2022
 **/
public interface Productor {

    default <T extends Serializable> void sendMessage(String topic, String tag, T message) {
        this.sendMessage(topic, tag, message, 0);
    }

    default <T extends Serializable> void sendMessage(String topic, T message) {
        this.sendMessage(topic, null, message, 0);
    }


    <T extends Serializable> void sendMessage(String topic, String tag, T message, int delayLevel);
}
